package com.ai.service.rocketMq;

/**
 * rocketMq消息生产者
 * @Author jiaok
 * @Date 2023-11-08 15:14
 */
public interface RocketMQProducerService {

    /**
     * 消息的异步投递
     * @param msgBody 实际消息内容
     * @param tag 消息标签
     * @param alarmRecordID  告警记录id
     */
     void asyncSendMsg(String msgBody,String tag,String alarmRecordID);

    /**
     * 消息的同步投递
     * @param msgBody 实际消息内容
     * @param tag 消息标签
     */
    public void synSendMsg(String msgBody,String tag) ;
}
